package ex.datastream.functions.function;

import ex.vo.Item;
import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.util.Collector;

public class FlatMapFuncByItem implements FlatMapFunction<Item, Object> {
    @Override
    public void flatMap(Item item, Collector<Object> collector)  {
            String name=item.getName()+"MyFlatMap";
            collector.collect(name);
    }
}
